1、引入springboot整合amqp的依赖org.springframework.bootspring-boot-starter-amqp2、application.yml配置server:port:8111spring:rabbitmq:port:5672host:localhostusername:guestpassword:guest#这个配置是保证提供者确保消息推送到交换机中，不管成不成功，都会回调publisher-confirm-type:correlated#保证交换机能把消息推送到队列中publisher-returns:truevirtual-host:/#这个配置是保证

目录IDEA简单测试Postman测试工具post请求接口测试工具swaggerKnife4j1.引入依赖2.配置3.常用注解4.接口测试JMeter什么是JMeter?JMeter安装配置1.官网下载2.下载后解压3.汉语设置JMeter的使用方法1.新建线程组2.设置参数3.添加取样器4.设置参数：协议，ip，端口，请求方式，路径5.添加查看结果树6.启动+查看结果IDEA简单测试Postman测试工具post请求头部携带token类型选择JSON接口测试工具swaggerhttps://apifox.com/swagger2，较多swagger3，Knife4jKnife4j的前身是sw

RocketMQ是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时、高可靠的消息发布与订阅服务。这篇文章，笔者整理了RocketMQ源码中创建线程的几点技巧，希望大家读完之后，能够有所收获。1创建单线程首先我们先温习下常用的创建单线程的两种方式：实现Runnable接口继承Thread类▍一、实现Runnable接口图中，MyRunnable类实现了Runnable接口的run方法，run方法中定义具体的任务代码或处理逻辑，而Runnable对象是作为线程构造函数的参数。▍二、继承Thread类线程实现类直接继承Thread，本质上也是实现Runnable接口的run方法。2单线

书名：代码本色：用编程模拟自然系统作者：DanielShiffman译者：周晗彬ISBN：978-7-115-36947-5目录5.17　整合代码：一个简单的交互式弹簧对于Box2D，手动设置物体的位置会破坏物理模拟。在toxiclibs中并不存在这样的问题。如果要移动粒子的位置，我们可以直接设置它的x坐标和y坐标。但在设置之前，我们最好先调用lock()函数。lock()函数的作用就是将物体锁在某个位置，等同于将Box2D物体的密度设成0。下面我将展示如何临时锁住一个粒子，然后移动它，最后将它解锁，让它继续参与物理模拟。假设你想在鼠标点击时移动一个粒子。if(mousePressed){p2

文章目录1.ElasticSearch根据ids查询文档2.SpringBoot整合ES实现ids查询1.ElasticSearch根据ids查询文档①索引文档，构造数据PUT/my_index/_doc/1{"price":10}PUT/my_index/_doc/2{"price":20}PUT/my_index/_doc/3{"price":30}②查询文档id为1或者2的文档：GET/my_index/_search{"query":{"ids":{"values":[1,2]}}}{"took":1,"timed_out":false,"_shards":{"total":1,"su

目录一．KafkaUtils.createDstream方式二．KafkaUtils.createDirectStream方式 温习Kafka是由Apache软件基金会开发的一个开源流处理平台,它使用Scala和Java语言编写，是一个基于Zookeeper系统的分布式发布订阅消息系统，该项目的设计初衷是为实时数据提供一个统一、高通量、低等待的消息传递平台。①、Kafka的众多优点：其优点具体：(1)解耦。Kafka具备消息系统的优点,只要生产者和消费者数据两端遵循接口约束，就可以自行扩展或修改数据处理的业务过程。(2)高吞吐量、低延迟。即使在非常廉价的机器上,Kafka也能做到每秒处理几十万

文章目录一、Docker安装Kafka1.创建网络2.安装zookeeper3.安装Kafka二、Kafka介绍1.Kafka简介三、SpringBoot整合Kafka1.引入pom依赖2.application.propertise配置3.HelloKafka(Producer)4.ConsumerKafka5.带回调的生产者6.自定义分区器7.kafka事务提交8.指定topic、partition、offset消费9.ConsumerAwareListenerErrorHandler异常处理器10.消息过滤器11.消息转发12.定时启动、停止监听器一、Docker安装Kafka1.创建网

文章目录一、教学讲解视频二、前言三、准备工作四、CASServer服务端搭建五、CASClient客户端搭建六、结尾一、教学讲解视频教学讲解视频地址：视频地址二、前言因为CAS支持HTTP请求访问，而我们是快速入门上手视频，所以这期教程就不教大家如何配置HTTPS了，如果需要使用HTTPS，可以参考其他博客去云服务器申请证书或者使用JDK自行生成一个证书。三、准备工作下载CASServer（直接下载压缩包就可以）这里我们用的是5.3版本的服务端，5.3之前的服务端都是maven项目，大于5.3的服务端就是gradle项目下载链接四、CASServer服务端搭建1.解压我们前面下载好的压缩包。2

原文链接ElasticSearch是个开源分布式搜索引擎，提供搜集、分析、存储数据三大功能。它的特点有：分布式，零配置，自动发现，索引自动分片，索引副本机制，restful风格接口，多数据源，自动搜索负载等。主要负责将日志索引并存储起来，方便业务方检索查询。ElasticSearch安装方式参考：Linux安装ElasticSearchLinux安装elasticsearch-headWindows安装ElasticSearch1Spring项目项目GitHub地址：https://github.com/Snowstorm0/learn-es项目Gitee地址：https://gitee.co

随着工作经验的积累，5年来也造了不少轮子，手头上也积攒了一系列自己开发的小程序等，各自都很独立，基本上都是业务相关性很强、或者实用性很强的，现在在考虑如何整合这些小程序。于是便有了下面的这番思考：一、程序同时支持参数从本地命令行输入、本地配置文件输入和grpc中心服务输入，并配备默认值和优先级。默认值的最佳形式就是无参数执行，普通人点击即用，扩大用户群体；（懂程序的人，才去传参配置程序，使用程序的高阶功能。）这意味着，每个小程序都应当有默认参数，这个默认参数应当是最常用的参数。由于参数输入一共存在以上描述的3种形式，但程序只需要选定一种形式入参，因此优先级也是一种变相的默认行为，[2023-0